package com.qing.spark;

import com.qing.spark.beans.Message;


import java.io.IOException;
import java.util.ArrayList;
import java.util.List;

/**
 * Created by wuliao on 2018/3/12.
 */
public class MessageDao {

//    public void saveMessages(List<Message> messages) {
//        HTable table = HBaseUtils.getInstance().getTable(getTableName());
//        List<Put> puts = new ArrayList();
//
//        for (Message msg : messages) {
//            Put put = new Put(String.valueOf(msg.getTime()).getBytes());
//
//            addColumn(put, "day", String.valueOf(msg.getDay()));
//            addColumn(put, "hour", String.valueOf(msg.getHour()));
//            addColumn(put, "minute", String.valueOf(msg.getMinute()));
//            addColumn(put, "second", String.valueOf(msg.getSecond()));
//            addColumn(put, "time", String.valueOf(msg.getTime()));
//
//            addColumn(put, "proxyIp", msg.getProxyIp());
//            addColumn(put, "srcIp", msg.getSrcIp());
//            addColumn(put, "srcPort", String.valueOf(msg.getInPort()));
//            addColumn(put, "outIp", msg.getOutIp());
//            addColumn(put, "outPort", String.valueOf(msg.getOutPort()));
//
//            addColumn(put, "host", msg.getHost());
//
//            puts.add(put);
//        }
//
//        try {
//            table.put(puts);
//        } catch (IOException e) {
//            e.printStackTrace();
//        }
//
//    }
//
//
//    @Override
//    protected String getFamily() {
//        return "data";
//    }
//
//    @Override
//    protected String getTableName() {
//        return "logger";
//    }

}
